# -*- coding: utf-8 -*-
from airflow.operators.python import PythonOperator
from .dm_cainiao_active_tn_v2_dt_success import main
from jms.dm.dm_cainiao_active_tn_v2_dt import jms_dm__dm_cainiao_active_tn_v2_dt
from jms.time_sensor.time_after_07_00 import time_after_07_00

jms_dm__dm_cainiao_active_tn_v2_dt_success = PythonOperator(
    task_id='jms_dm__dm_cainiao_active_tn_v2_dt_success',
    email='guoruiling@jtexpress.com',
    pool='unlimited_pool',
    python_callable=main,
    op_args=['{{ execution_date | cst_ds }}', '{{ var.json.mysq_sync_status2kafka }}'],
)


jms_dm__dm_cainiao_active_tn_v2_dt_success << [
    jms_dm__dm_cainiao_active_tn_v2_dt,time_after_07_00
]